#ifndef __udpspeed_tactics_h__
#define __udpspeed_tactics_h__ 1
#include "sys.h"
#include "cJSON.h"
typedef struct udpspeedTactics{
    char ip[32];
    int tcpPort;
    int udpPort;
    int threads;
    int timeout;
    float threshold;
    float discardPercent;
    char businessTag[64];
    char kafkaTopic[64];
    TAILQ_ENTRY(udpspeedTactics) entry;
}udpspeedTactics_t;
TAILQ_HEAD(udpspeedTactics_head, udpspeedTactics);

typedef struct{
    char *taskId;
    char *version;
    char *kafka_url;
    int down_count, up_count;
    struct udpspeedTactics_head down_head, up_head;
    cJSON *result;
    pthread_mutex_t mutex;
    pthread_cond_t cond;
}udpspeed_tactics_t;

void* do_udpspeed_tactics(void* arg, char *nodeUrl, char *probeId);
#endif